//package com.zhz.mall.portal.kakfa;
//
//import java.lang.annotation.*;
//
///**
// * KafkaListener
// * <p>
// * kafka 消息监听注解
// *
// * @author zhouhengzhe
// */
//@Target(ElementType.METHOD)
//@Retention(RetentionPolicy.RUNTIME)
//@Documented
//public @interface KafkaListener {
//
//    /**
//     * 监听的主题
//     */
//    String topic();
//
//    /**
//     * 是否异步执行
//     */
//    boolean async() default true;
//
//    /**
//     * 是否进行参数校验（或直接给参数加上 @Validated 注解）
//     */
//    boolean valid() default false;
//
//}
